//websocket服务器程序
//1导入
// const ws = require("nodejs-websocket");
import ws from "nodejs-websocket";
var connlist = [];
//2创建websocket服务器   conn ->  连接通道
var server = ws
  .createServer(conn => {
    // 将链接通道添加到数组中保存
    connlist.push(conn);
    console.log("有客户端访问了", connlist.length);
    // 谁连接服务器就给谁发欢迎词
    // conn.sendText('你好我是京东客服，有什么可以为您服务')
    // 接收客户端返回的数据
    conn.on("text", function (str) {
      // console.log("将数据发送给当前连接的客户端");
      // 遍历连接数组，并发送数据
      for (var i = 0; i < connlist.length; i++) {
        connlist[i].sendText(str);
      }
    });
    //客户端关闭连接
    conn.on("close", function () {
      console.log("关闭");
      connlist.splice(connlist.indexOf(conn), 1);
      console.log("当前连接数量", connlist.length);
    });
    conn.on("error", function (code, reason) {
      console.log("异常事件", reason);
    });
  })
  .listen(3000, function () {
    console.log("启动成功了");
  });
